e4e09606f1bf4ad1eeee5b98133fa415c5ddc92a,src/org/jgroups/protocols/ENCRYPT.java,ENCRYPT,sendDown,#Event#,1009

Before Change


        if (msg.getBuffer() != null) {
            // copy neeeded because same message (object) may be retransmitted -> no double encryption
            Message msgEncrypted = msg.copy(false);
            msgEncrypted.setBuffer(encryptMessage(symEncodingCipher, msg.getBuffer()));
            passDown(new Event(Event.MSG, msgEncrypted));
            return;
        }

After Change


        }

        Message msg = (Message) evt.getArg();
        if(msg.getLength() == 0) {
            passDown(evt);
            return;
        }

        EncryptHeader hdr=new EncryptHeader(EncryptHeader.ENCRYPT, getSymVersion());
        hdr.encrypt_entire_msg=this.encrypt_entire_message;

        if(encrypt_entire_message) {
            byte[] serialized_msg=Util.streamableToByteBuffer(msg);
            byte[] encrypted_msg=encryptMessage(symEncodingCipher, serialized_msg);
            Message tmp=msg.copy(false); // we need to preserve headers which may already be present
            tmp.setBuffer(encrypted_msg);
            tmp.setSrc(local_addr);
            tmp.putHeader(EncryptHeader.KEY, hdr);
            passDown(new Event(Event.MSG, tmp));
            return;
        }


        // put our encrypt header on the message
        msg.putHeader(EncryptHeader.KEY, hdr);

        // copy neeeded because same message (object) may be retransmitted -> no double encryption
        Message msgEncrypted = msg.copy(false);
        msgEncrypted.setBuffer(encryptMessage(symEncodingCipher, msg.getBuffer()));
        passDown(new Event(Event.MSG, msgEncrypted));
    }